63dd20dbd11a7f803b9103ce7a97a88827b611e5,transports/vm/src/main/java/org/mule/transport/vm/VMMessageReceiver.java,VMMessageReceiver,getFirstMessages,#,189

Before Change


            // keep batching if more events are available
            for (int i = 0; i < batchSize && message != null; i++)
            {
                message = (MuleEvent)queue.poll(0);
                if (message != null)
                {
                    messages.add(new DefaultMuleMessage(message.getMessage(), endpoint.getMuleContext()));

After Change


            // keep batching if more events are available
            for (int i = 0; i < batchSize && message != null; i++)
            {
                message = getMessage(queue, 0);
                if (message != null)
                {
                    messages.add(new DefaultMuleMessage(message, endpoint.getMuleContext()));